package com.atguigu.gmall.realtime.bean;

import lombok.Getter;
import lombok.Setter;

/**
 * 配置表实体类对象
 *
 * @author lvbingbing
 * @date 2022-03-19 09:33
 */
@Getter
@Setter
public class TableProcess {
    /**
     * 维度表
     */
    public static final String SINK_TYPE_HBASE = "hbase";

    /**
     * 事实表
     */
    public static final String SINK_TYPE_KAFKA = "kafka";

    public static final String SINK_TYPE_CK = "clickhouse";

    /**
     * 来源表
     */
    private String sourceTable;

    /**
     * 操作类型 insert、update、delete
     */
    private String operateType;

    /**
     * 输出类型 hbase、kafka
     */
    private String sinkType;

    /**
     * 输出表(主题)
     */
    private String sinkTable;

    /**
     * 输出字段
     */
    private String sinkColumns;

    /**
     * 主键字段
     */
    private String sinkPk;

    /**
     * 建表扩展
     */
    private String sinkExtend;
}